package net.expectx.pay.script;

import com.alibaba.fastjson.JSON;
import com.google.common.collect.Maps;
import net.expectx.pay.script.redis.RedisMsgSubListener;
import net.expectx.pay.script.redis.RedisUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.Map;


/**
 * @author Administrator
 */
public class Main {
    private static final Logger LOGGER = LoggerFactory.getLogger(Main.class);

    public static void subscribeMsg() {
        LOGGER.info("Start monitoring");
        RedisMsgSubListener pubsub = new RedisMsgSubListener();
        RedisUtil.subscribeMsg(pubsub, "PublishMsg");


    }
    public static void main(String [] args){
       subscribeMsg();
    }
}
